/*
 *  Copyright 2020-2025 the original author or authors.
 *  You cannot use this file unless authorized by the author.
 */

package org.ipig.computing.spark.conf;

import lombok.Data;
import lombok.ToString;

import java.io.Serializable;

/**
 * Spark Kafka Conf
 *
 * @author <a href="mailto:comchnts@163.com">chinats</a>
 * @since 1.0
 */
@Data
@ToString
public class SparkKafkaConf<KafkaConsumerConf,KafkaProducerConf>  implements Serializable {
    public SparkKafkaConf(){
        super();
    }

    /**
     *
     * @param producerConf
     * @param consumerConf
     */
    public SparkKafkaConf(KafkaProducerConf producerConf,KafkaConsumerConf consumerConf){
        super();
        this.producerConf=producerConf;
        this.consumerConf=consumerConf;
    }
    //kafka消费配置
    private KafkaConsumerConf consumerConf;
    //kafka消费配置
    private KafkaProducerConf producerConf;
}